package cn.bytets.speed.exchange;

import cn.bytets.rpc.api.exchange.DefaultFuture;
import cn.bytets.rpc.api.message.Request;
import cn.bytets.rpc.api.message.Response;

import java.util.concurrent.ExecutionException;

public class TestDefaultFuture {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        Request request = new Request();
        DefaultFuture future = DefaultFuture.newFuture(null, request, 10000);
        Response response = (Response)future.get();
    }
}
